#include "redis_publisher.h"
using namespace plugins::rediss;
#include <winsock2.h> // 包含 Winsock 头文件
/**
 * 实现发布消息
 * @param argc
 * @param argv
 * @return
 */
int main(int argc, char *argv[]) {
    //// 初始化 Winsock 库
    //WSADATA wsaData;
    //int result = WSAStartup(MAKEWORD(2, 2), &wsaData);
    //if (result != 0) {
    //    std::cerr << "WSAStartup failed with error: " << result << std::endl;
    //    return 1;
    //}

    RedisPublisher publisher;

    bool ret = publisher.init();
    if (!ret) {
        std::cout << "Init failed." << std::endl;
        return 0;
    }

    ret = publisher.connect();
    if (!ret) {
        std::cout << "connect failed." << std::endl;
        return 0;
    }

    while (true) {
        //设置频道名称，频道内容
        publisher.publish("每日报道", "欢迎订阅每日报道的新闻!");
#ifdef _WIN32
        Sleep(1000); // Windows 下使用 Sleep 函数
#else
        sleep(1);    // Linux 下使用 sleep 函数
#endif
    
    }

    publisher.disconnect();
    publisher.uninit();
    return 0;
}